package com.horay.springclouddemo.stream.multiple.consumer;

import com.horay.springclouddemo.stream.multiple.consumer.message.MessageSource;
import com.horay.springclouddemo.stream.multiple.consumer.message.MessageSink;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;

/**
 * 服务启动类
 *
 * @author heyingcheng
 * @date 2020/3/29 16:09
 */
@EnableBinding(value = {MessageSource.class, MessageSink.class})
@SpringBootApplication
public class StreamMultipleConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(StreamMultipleConsumerApplication.class, args);
    }

}
